p-pipe

Basic Pipeline

This feature allows you to create a basic pipeline of asynchronous functions. In this example, the `add` function increments the input by 1, and the `multiply` function doubles the result. The pipeline processes the input `5` to produce the output `12`.

const pPipe = require('p-pipe');

const add = async x => x + 1;
const multiply = async x => x * 2;

const pipeline = pPipe(add, multiply);

pipeline(5).then(result => console.log(result)); // 12

Error Handling

This feature demonstrates how p-pipe handles errors in the pipeline. If any function in the pipeline throws an error, the pipeline will stop executing and return the error. In this example, the `throwError` function throws an error, which is caught and logged.

const pPipe = require('p-pipe');

const add = async x => x + 1;
const throwError = async x => { throw new Error('Something went wrong'); };
const multiply = async x => x * 2;

const pipeline = pPipe(add, throwError, multiply);

pipeline(5).catch(error => console.error(error.message)); // 'Something went wrong'

Synchronous Functions

This feature shows that p-pipe can also handle synchronous functions. The pipeline processes the input `5` to produce the output `12`, similar to the asynchronous example.

const pPipe = require('p-pipe');

const add = x => x + 1;
const multiply = x => x * 2;

const pipeline = pPipe(add, multiply);

pipeline(5).then(result => console.log(result)); // 12